package com.codi.bus.util;

import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * @Author: zengxl
 * @Description:
 * @Date:2017/12/22 20:09
 */
public class HttpClientUtil {
    private static final CloseableHttpClient httpclient = HttpClients.createDefault();
/*
    public static void main(String[] args)  throws Exception{
        String url = "http://sms.cd121.com/mc-receiver-web/message/sendsms";
        Map<String, String> temp = Maps.newHashMap();
        temp.put("validcode","123123");
        Map<String, String> map = Maps.newHashMap();
        map.put("templateCode","SMS_003");
        map.put("mobile","18958058213");
        map.put("content",JsonUtil.map2json(temp));
        map.put("requestIp","");
        System.out.println(sendPost(url,map));
    }*/
    /**
     * 发送HttpGet请求
     * @param url
     * @return
     */
    public static String sendGet(String url,Map<String,String> headerMap) {

        HttpGet httpget = new HttpGet(url);
        if(headerMap != null && headerMap.size() > 0){
            for(String key : headerMap.keySet()){
                String value = headerMap.get(key);
                httpget.setHeader(key,value);
            }
        }
        CloseableHttpResponse response = null;
        try {
            response = httpclient.execute(httpget);
        } catch (IOException e1) {
            e1.printStackTrace();
        }
        String result = null;
        try {
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                result = EntityUtils.toString(entity);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                response.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return result;
    }

    /**
     * 发送HttpPost请求，参数为map
     * @param url
     * @param map
     * @return
     */
    public static String sendPost(String url, Map<String, String> map,Map<String,String> headerMap) {
        List<NameValuePair> formparams = new ArrayList<NameValuePair>();
        for (Map.Entry<String, String> entry : map.entrySet()) {
            formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
        }
        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
        HttpPost httppost = new HttpPost(url);
        if(headerMap != null && headerMap.size() > 0){
            for(String key : headerMap.keySet()){
                String value = headerMap.get(key);
                httppost.setHeader(key,value);
            }
        }

        httppost.setEntity(entity);
        CloseableHttpResponse response = null;
        try {
            response = httpclient.execute(httppost);
        } catch (IOException e) {
            e.printStackTrace();
        }
        HttpEntity entity1 = response.getEntity();
        String result = null;
        try {
            result = EntityUtils.toString(entity1);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

    /**
     * 发送不带参数的HttpPost请求
     * @param url
     * @return
     */
    public static String sendPost(String url,Map<String,String> headerMap) {
        HttpPost httppost = new HttpPost(url);
        if(headerMap != null && headerMap.size() > 0){
            for(String key : headerMap.keySet()){
                String value = headerMap.get(key);
                httppost.setHeader(key,value);
            }
        }
        CloseableHttpResponse response = null;
        try {
            response = httpclient.execute(httppost);
        } catch (IOException e) {
            e.printStackTrace();
        }
        HttpEntity entity = response.getEntity();
        String result = null;
        try {
            result = EntityUtils.toString(entity);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

}
